# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms_target_all.dwm.dwm_analysis_target_network_sum_week_dt import jms_dwm__dwm_analysis_target_network_sum_week_dt

jms_oracle__dwm_analysis_target_network_sum_week_dt = BashOperator(
    task_id='jms_oracle__dwm_analysis_target_network_sum_week_dt',
    execution_timeout=timedelta(hours=2),
    email=['suning@jtexpress-scm.com','yl_etl@yl-scm.com'],
    bash_command="jms_target_all/oracle/dwm_analysis_target_network_sum_week_dt/execute.sh",
    pool='spmi_apack',
    retries=1,
    pool_slots=1,
)

jms_oracle__dwm_analysis_target_network_sum_week_dt << [
    jms_dwm__dwm_analysis_target_network_sum_week_dt,
]